package com.qingyan.flink.core.properties;

import lombok.Getter;
import lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;

import java.util.Map;

/**
 * Flink配置
 *
 * @author csp 2023-12-22
 */
@ConfigurationProperties(prefix = "flink")
@Setter
@Getter
public class FlinkProperties {

    private String pipelineName;

    private Integer checkpoint;

    private Integer parallelism;

    private String checkpointStorage;

    private Integer checkpointInterval;

    private Map<String, String> sourceConfig;

    private Map<String, String> sinkConfig;

    private Map<String, FlinkDataSourceProperties> datasource;

    private Map<String, FlinkTransProperties> trans;

}
